import matplotlib
import matplotlib.pyplot as plt
from matplotlib.ticker import FormatStrFormatter
import matplotlib.patches as mpatches
import matplotlib.gridspec as gridspec
import numpy as np
from pyuvdata import UVCal, UVData, UVFlag
import pyuvdata
import os
import sys
import glob
import uvtools as uvt
from astropy.time import Time
from astropy.coordinates import EarthLocation, SkyCoord, AltAz, Angle
import pandas
import warnings
import copy
from hera_notebook_templates import utils
import hera_qm
from hera_mc import cm_hookup
import h5py
import importlib
from scipy import stats
import scipy
import pandas as pd
from IPython.display import display, HTML
#warnings.filterwarnings('ignore')
%matplotlib inline
%config InlineBackend.figure_format = 'retina'
#get data location
JD = os.environ['JULIANDATE']
data_path = os.environ['DATA_PATH']
nb_outdir = os.environ['NB_OUTDIR']
utc = Time(JD, format='jd').datetime
print(f'JD = {JD}')
print(f'Date = {utc.month}-{utc.day}-{utc.year}')
print(f'data_path = "{data_path}"')
JD = 2459715 Date = 5-15-2022 data_path = "/mnt/sn1/2459715"
# Load in data
HHfiles, difffiles, uvdx, uvdy = utils.load_data_ds(data_path,JD)
uvd = UVData()
uvd_diff = UVData()
uvd.read(HHfiles[0])
use_ants = [int(ant) for ant in uvd.get_ants()]
bls = [(ant, ant) for ant in use_ants]
uvd.read(HHfiles[::10], skip_bad_files=True, bls=bls)
uvd_diff.read(difffiles[::10], skip_bad_files=True, bls=bls)
lsts = uvd.lst_array
flagfile = glob.glob(os.path.join(HHfiles[0].split('zen')[0],'zen.{}*total_stage_1_threshold_flags.h5'.format(JD)))
uvf = UVFlag()
uvf.read(flagfile)
bls = [(ant, ant) for ant in uvd.get_ants()]
times_uvf = np.unique(uvf.time_array)
times_uvd = np.unique(uvd.time_array)
idx_times = [np.where(time_uvd == times_uvf)[0][0] for time_uvd in times_uvd]
uvd.flag_array[:,0,:,:] = np.repeat(uvf.flag_array[idx_times], len(bls), axis=0)
1848 sum files found between JDs 2459715.25341 and 2459715.66657 1848 diff files found between JDs 2459715.25341 and 2459715.66657
Shows the LSTs (in hours) and JDs for which data is collected. Green represents data, red means no data.
utils.plot_lst_coverage(uvd)
Delay spectrum CLEANed using uvtools.dspec.high_pass_fourier_filter with 7th-order Blackman-Harris window function. Odd/even visibilities are used to remove noise bias.
_data_cleaned_sq, d_even, d_odd = utils.clean_ds(bls, uvd, uvd_diff, N_threads=14)
These plots show autocorrelation delay spectrum waterfalls of each antenna that is active and whose status qualifies for this notebook. For nn/ee polarization, the autocorrelation delay spectrum is normalized by the max of the delay spectrum. For ne polarization, the autocorrelation delay spectrum is normalized by max(sqrt(|nn| |ee|)). ne and en are the same for autocorrelations, and thus only ne is shown here. The delay spectra are presented in dB with 10log10($|\tilde{V}|$).
For each node, antennas are ordered by SNAP number, and within that by SNAP input number. The antenna number label color corresponds to the a priori status of that antenna.
utils.plot_wfds(uvd, _data_cleaned_sq, 0)
--------------------------------------------------------------------------- OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 63 try: # This tries thrice with 5sec sleeps in between ---> 64 iengine = inspect(engine) 65 except OperationalError: # pragma: no cover ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8) During handling of the above exception, another exception occurred: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 69 try: ---> 70 iengine = inspect(engine) 71 except OperationalError: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8) During handling of the above exception, another exception occurred: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) /tmp/ipykernel_18964/1336185259.py in <module> ----> 1 utils.plot_wfds(uvd, _data_cleaned_sq, 0) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_notebook_templates/utils.py in plot_wfds(uvd, _data_sq, pol) 2101 if a not in ants: 2102 continue -> 2103 status = get_ant_status(a,jd) 2104 abb = status_abbreviations[status] 2105 ax = axes[i,j] ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_notebook_templates/utils.py in get_ant_status(ant, jd) 406 407 def get_ant_status(ant,jd): --> 408 h = cm_active.ActiveData(at_date=jd) 409 h.load_apriori() 410 if f'HH{ant}:A' in h.apriori.keys(): ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/cm_active.py in __init__(self, session, at_date, at_time, float_format) 43 from . import mc 44 ---> 45 db = mc.connect_to_mc_db(None) 46 session = db.sessionmaker() 47 self.session = session ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/mc.py in connect_to_mc_db(args, forced_db_name, check_connect) 236 db = DeclarativeDB(db_url) 237 elif db_mode == "production": --> 238 db = AutomappedDB(db_url) 239 else: 240 raise RuntimeError( ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/mc.py in __init__(self, db_url) 89 90 with self.sessionmaker() as session: ---> 91 if not is_valid_database(MCDeclarativeBase, session): 92 raise RuntimeError( 93 "database {0} does not match expected schema".format(db_url) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 71 except OperationalError: 72 time.sleep(5) ---> 73 iengine = inspect(engine) 74 75 errors = False ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 62 if reg is True: 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: 66 break ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 180 @inspection._inspects(Engine) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 184 @inspection._inspects(Connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 115 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self 119 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 126 def _init_engine(self, engine): 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True 130 self.dialect = self.engine.dialect ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3195 """ 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 3199 @util.deprecated( ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 94 connection 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) 98 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3274 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 3278 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3245 if connection is None: 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) 3249 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2099 elif should_wrap: 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) 2103 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3241 dialect = self.dialect 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: 3245 if connection is None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 308 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 312 def _return_conn(self, record): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 866 def _checkout(cls, pool, threadconns=None, fairy=None): 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 870 fairy._pool = pool ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 474 @classmethod 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: 478 dbapi_connection = rec.get_connection() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 144 except: 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: 148 return self._do_get() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 70 compat.raise_( 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) 74 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 141 if self._inc_overflow(): 142 try: --> 143 return self._create_connection() 144 except: 145 with util.safe_reraise(): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 254 """Called by subclasses to create a new ConnectionRecord.""" 255 --> 256 return _ConnectionRecord(self) 257 258 def _invalidate(self, connection, exception=None, _checkin=True): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 369 self.__pool = pool 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() 373 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 664 except Exception as e: 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: 668 # in SQLAlchemy 1.4 the first_connect event is not used by ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 70 compat.raise_( 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) 74 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 659 try: 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) 663 self.fresh = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 588 if connection is not None: 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 592 creator = pop_kwarg("creator", connect) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 582 def connect(self, *cargs, **cparams): 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 586 def create_connect_args(self, url): ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 125 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: 129 conn.cursor_factory = cursor_factory OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8)
utils.plot_wfds(uvd, _data_cleaned_sq, 1)
--------------------------------------------------------------------------- OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 63 try: # This tries thrice with 5sec sleeps in between ---> 64 iengine = inspect(engine) 65 except OperationalError: # pragma: no cover ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8) During handling of the above exception, another exception occurred: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 69 try: ---> 70 iengine = inspect(engine) 71 except OperationalError: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8) During handling of the above exception, another exception occurred: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) /tmp/ipykernel_18964/3725994941.py in <module> ----> 1 utils.plot_wfds(uvd, _data_cleaned_sq, 1) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_notebook_templates/utils.py in plot_wfds(uvd, _data_sq, pol) 2028 String of polarization 2029 """ -> 2030 nodes, antDict, inclNodes = generate_nodeDict(uvd) 2031 ants = uvd.get_ants() 2032 sorted_ants = sort_antennas(uvd) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_notebook_templates/utils.py in generate_nodeDict(uv) 1731 1732 antnums = uv.get_ants() -> 1733 h = cm_hookup.Hookup() 1734 x = h.get_hookup('HH') 1735 nodes = {} ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/cm_hookup.py in __init__(self, session) 34 def __init__(self, session=None): 35 if session is None: # pragma: no cover ---> 36 db = mc.connect_to_mc_db(None) 37 self.session = db.sessionmaker() 38 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/mc.py in connect_to_mc_db(args, forced_db_name, check_connect) 236 db = DeclarativeDB(db_url) 237 elif db_mode == "production": --> 238 db = AutomappedDB(db_url) 239 else: 240 raise RuntimeError( ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/mc.py in __init__(self, db_url) 89 90 with self.sessionmaker() as session: ---> 91 if not is_valid_database(MCDeclarativeBase, session): 92 raise RuntimeError( 93 "database {0} does not match expected schema".format(db_url) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 71 except OperationalError: 72 time.sleep(5) ---> 73 iengine = inspect(engine) 74 75 errors = False ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 62 if reg is True: 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: 66 break ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 180 @inspection._inspects(Engine) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 184 @inspection._inspects(Connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 115 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self 119 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 126 def _init_engine(self, engine): 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True 130 self.dialect = self.engine.dialect ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3195 """ 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 3199 @util.deprecated( ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 94 connection 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) 98 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3274 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 3278 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3245 if connection is None: 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) 3249 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2099 elif should_wrap: 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) 2103 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3241 dialect = self.dialect 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: 3245 if connection is None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 308 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 312 def _return_conn(self, record): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 866 def _checkout(cls, pool, threadconns=None, fairy=None): 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 870 fairy._pool = pool ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 474 @classmethod 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: 478 dbapi_connection = rec.get_connection() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 144 except: 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: 148 return self._do_get() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 70 compat.raise_( 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) 74 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 141 if self._inc_overflow(): 142 try: --> 143 return self._create_connection() 144 except: 145 with util.safe_reraise(): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 254 """Called by subclasses to create a new ConnectionRecord.""" 255 --> 256 return _ConnectionRecord(self) 257 258 def _invalidate(self, connection, exception=None, _checkin=True): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 369 self.__pool = pool 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() 373 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 664 except Exception as e: 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: 668 # in SQLAlchemy 1.4 the first_connect event is not used by ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 70 compat.raise_( 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) 74 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 659 try: 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) 663 self.fresh = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 588 if connection is not None: 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 592 creator = pop_kwarg("creator", connect) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 582 def connect(self, *cargs, **cparams): 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 586 def create_connect_args(self, url): ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 125 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: 129 conn.cursor_factory = cursor_factory OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8)
utils.plot_wfds(uvd, _data_cleaned_sq, 2)
--------------------------------------------------------------------------- OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 63 try: # This tries thrice with 5sec sleeps in between ---> 64 iengine = inspect(engine) 65 except OperationalError: # pragma: no cover ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8) During handling of the above exception, another exception occurred: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 69 try: ---> 70 iengine = inspect(engine) 71 except OperationalError: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8) During handling of the above exception, another exception occurred: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) /tmp/ipykernel_18964/859526658.py in <module> ----> 1 utils.plot_wfds(uvd, _data_cleaned_sq, 2) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_notebook_templates/utils.py in plot_wfds(uvd, _data_sq, pol) 2028 String of polarization 2029 """ -> 2030 nodes, antDict, inclNodes = generate_nodeDict(uvd) 2031 ants = uvd.get_ants() 2032 sorted_ants = sort_antennas(uvd) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_notebook_templates/utils.py in generate_nodeDict(uv) 1731 1732 antnums = uv.get_ants() -> 1733 h = cm_hookup.Hookup() 1734 x = h.get_hookup('HH') 1735 nodes = {} ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/cm_hookup.py in __init__(self, session) 34 def __init__(self, session=None): 35 if session is None: # pragma: no cover ---> 36 db = mc.connect_to_mc_db(None) 37 self.session = db.sessionmaker() 38 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/mc.py in connect_to_mc_db(args, forced_db_name, check_connect) 236 db = DeclarativeDB(db_url) 237 elif db_mode == "production": --> 238 db = AutomappedDB(db_url) 239 else: 240 raise RuntimeError( ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/mc.py in __init__(self, db_url) 89 90 with self.sessionmaker() as session: ---> 91 if not is_valid_database(MCDeclarativeBase, session): 92 raise RuntimeError( 93 "database {0} does not match expected schema".format(db_url) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 71 except OperationalError: 72 time.sleep(5) ---> 73 iengine = inspect(engine) 74 75 errors = False ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 62 if reg is True: 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: 66 break ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 180 @inspection._inspects(Engine) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 184 @inspection._inspects(Connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 115 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self 119 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 126 def _init_engine(self, engine): 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True 130 self.dialect = self.engine.dialect ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3195 """ 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 3199 @util.deprecated( ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 94 connection 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) 98 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3274 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 3278 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3245 if connection is None: 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) 3249 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2099 elif should_wrap: 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) 2103 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3241 dialect = self.dialect 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: 3245 if connection is None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 308 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 312 def _return_conn(self, record): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 866 def _checkout(cls, pool, threadconns=None, fairy=None): 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 870 fairy._pool = pool ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 474 @classmethod 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: 478 dbapi_connection = rec.get_connection() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 144 except: 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: 148 return self._do_get() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 70 compat.raise_( 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) 74 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 141 if self._inc_overflow(): 142 try: --> 143 return self._create_connection() 144 except: 145 with util.safe_reraise(): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 254 """Called by subclasses to create a new ConnectionRecord.""" 255 --> 256 return _ConnectionRecord(self) 257 258 def _invalidate(self, connection, exception=None, _checkin=True): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 369 self.__pool = pool 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() 373 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 664 except Exception as e: 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: 668 # in SQLAlchemy 1.4 the first_connect event is not used by ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 70 compat.raise_( 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) 74 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 659 try: 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) 663 self.fresh = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 588 if connection is not None: 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 592 creator = pop_kwarg("creator", connect) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 582 def connect(self, *cargs, **cparams): 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 586 def create_connect_args(self, url): ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 125 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: 129 conn.cursor_factory = cursor_factory OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8)
This plot shows the relative amplitude at 2700 ns feature. The relative amplitude is calculated in dB with the mean amplitude at 2500-3000 ns compared to the mean amplitude at 2000-2500 ns. Larger values of relative feature amplitude indicate higher probability of detecting the peak at 2700 ns. Antennas in the same node are grouped by the shaded region.
utils.plot_antFeatureMap_2700ns(uvd, _data_cleaned_sq, JD, pol='nn')
--------------------------------------------------------------------------- OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 63 try: # This tries thrice with 5sec sleeps in between ---> 64 iengine = inspect(engine) 65 except OperationalError: # pragma: no cover ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8) During handling of the above exception, another exception occurred: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 69 try: ---> 70 iengine = inspect(engine) 71 except OperationalError: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8) During handling of the above exception, another exception occurred: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) /tmp/ipykernel_18964/3548496956.py in <module> ----> 1 utils.plot_antFeatureMap_2700ns(uvd, _data_cleaned_sq, JD, pol='nn') ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_notebook_templates/utils.py in plot_antFeatureMap_2700ns(uvd, _data_sq, JD, pol) 2221 2222 fig = plt.figure(figsize=(14,10)) -> 2223 nodes, antDict, inclNodes = generate_nodeDict(uvd) 2224 antnums = uvd.get_ants() 2225 cmap = plt.get_cmap('inferno') ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_notebook_templates/utils.py in generate_nodeDict(uv) 1731 1732 antnums = uv.get_ants() -> 1733 h = cm_hookup.Hookup() 1734 x = h.get_hookup('HH') 1735 nodes = {} ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/cm_hookup.py in __init__(self, session) 34 def __init__(self, session=None): 35 if session is None: # pragma: no cover ---> 36 db = mc.connect_to_mc_db(None) 37 self.session = db.sessionmaker() 38 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/mc.py in connect_to_mc_db(args, forced_db_name, check_connect) 236 db = DeclarativeDB(db_url) 237 elif db_mode == "production": --> 238 db = AutomappedDB(db_url) 239 else: 240 raise RuntimeError( ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/mc.py in __init__(self, db_url) 89 90 with self.sessionmaker() as session: ---> 91 if not is_valid_database(MCDeclarativeBase, session): 92 raise RuntimeError( 93 "database {0} does not match expected schema".format(db_url) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 71 except OperationalError: 72 time.sleep(5) ---> 73 iengine = inspect(engine) 74 75 errors = False ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 62 if reg is True: 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: 66 break ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 180 @inspection._inspects(Engine) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 184 @inspection._inspects(Connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 115 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self 119 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 126 def _init_engine(self, engine): 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True 130 self.dialect = self.engine.dialect ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3195 """ 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 3199 @util.deprecated( ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 94 connection 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) 98 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3274 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 3278 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3245 if connection is None: 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) 3249 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2099 elif should_wrap: 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) 2103 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3241 dialect = self.dialect 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: 3245 if connection is None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 308 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 312 def _return_conn(self, record): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 866 def _checkout(cls, pool, threadconns=None, fairy=None): 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 870 fairy._pool = pool ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 474 @classmethod 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: 478 dbapi_connection = rec.get_connection() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 144 except: 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: 148 return self._do_get() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 70 compat.raise_( 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) 74 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 141 if self._inc_overflow(): 142 try: --> 143 return self._create_connection() 144 except: 145 with util.safe_reraise(): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 254 """Called by subclasses to create a new ConnectionRecord.""" 255 --> 256 return _ConnectionRecord(self) 257 258 def _invalidate(self, connection, exception=None, _checkin=True): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 369 self.__pool = pool 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() 373 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 664 except Exception as e: 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: 668 # in SQLAlchemy 1.4 the first_connect event is not used by ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 70 compat.raise_( 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) 74 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 659 try: 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) 663 self.fresh = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 588 if connection is not None: 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 592 creator = pop_kwarg("creator", connect) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 582 def connect(self, *cargs, **cparams): 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 586 def create_connect_args(self, url): ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 125 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: 129 conn.cursor_factory = cursor_factory OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8)
<Figure size 1008x720 with 0 Axes>
utils.plot_antFeatureMap_2700ns(uvd, _data_cleaned_sq, JD, pol='ee')
--------------------------------------------------------------------------- OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 63 try: # This tries thrice with 5sec sleeps in between ---> 64 iengine = inspect(engine) 65 except OperationalError: # pragma: no cover ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8) During handling of the above exception, another exception occurred: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 69 try: ---> 70 iengine = inspect(engine) 71 except OperationalError: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8) During handling of the above exception, another exception occurred: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) /tmp/ipykernel_18964/1081643923.py in <module> ----> 1 utils.plot_antFeatureMap_2700ns(uvd, _data_cleaned_sq, JD, pol='ee') ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_notebook_templates/utils.py in plot_antFeatureMap_2700ns(uvd, _data_sq, JD, pol) 2221 2222 fig = plt.figure(figsize=(14,10)) -> 2223 nodes, antDict, inclNodes = generate_nodeDict(uvd) 2224 antnums = uvd.get_ants() 2225 cmap = plt.get_cmap('inferno') ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_notebook_templates/utils.py in generate_nodeDict(uv) 1731 1732 antnums = uv.get_ants() -> 1733 h = cm_hookup.Hookup() 1734 x = h.get_hookup('HH') 1735 nodes = {} ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/cm_hookup.py in __init__(self, session) 34 def __init__(self, session=None): 35 if session is None: # pragma: no cover ---> 36 db = mc.connect_to_mc_db(None) 37 self.session = db.sessionmaker() 38 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/mc.py in connect_to_mc_db(args, forced_db_name, check_connect) 236 db = DeclarativeDB(db_url) 237 elif db_mode == "production": --> 238 db = AutomappedDB(db_url) 239 else: 240 raise RuntimeError( ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/mc.py in __init__(self, db_url) 89 90 with self.sessionmaker() as session: ---> 91 if not is_valid_database(MCDeclarativeBase, session): 92 raise RuntimeError( 93 "database {0} does not match expected schema".format(db_url) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 71 except OperationalError: 72 time.sleep(5) ---> 73 iengine = inspect(engine) 74 75 errors = False ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 62 if reg is True: 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: 66 break ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 180 @inspection._inspects(Engine) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 184 @inspection._inspects(Connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 115 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self 119 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 126 def _init_engine(self, engine): 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True 130 self.dialect = self.engine.dialect ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3195 """ 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 3199 @util.deprecated( ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 94 connection 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) 98 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3274 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 3278 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3245 if connection is None: 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) 3249 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2099 elif should_wrap: 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) 2103 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3241 dialect = self.dialect 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: 3245 if connection is None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 308 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 312 def _return_conn(self, record): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 866 def _checkout(cls, pool, threadconns=None, fairy=None): 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 870 fairy._pool = pool ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 474 @classmethod 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: 478 dbapi_connection = rec.get_connection() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 144 except: 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: 148 return self._do_get() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 70 compat.raise_( 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) 74 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 141 if self._inc_overflow(): 142 try: --> 143 return self._create_connection() 144 except: 145 with util.safe_reraise(): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 254 """Called by subclasses to create a new ConnectionRecord.""" 255 --> 256 return _ConnectionRecord(self) 257 258 def _invalidate(self, connection, exception=None, _checkin=True): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 369 self.__pool = pool 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() 373 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 664 except Exception as e: 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: 668 # in SQLAlchemy 1.4 the first_connect event is not used by ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 70 compat.raise_( 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) 74 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 659 try: 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) 663 self.fresh = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 588 if connection is not None: 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 592 creator = pop_kwarg("creator", connect) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 582 def connect(self, *cargs, **cparams): 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 586 def create_connect_args(self, url): ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 125 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: 129 conn.cursor_factory = cursor_factory OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8)
<Figure size 1008x720 with 0 Axes>
This plot shows a matrix representing the 2700ns feature correlation of each baseline. The color bar indicates the amplitude of 2700ns (mean amplitude of 2500-3000ns delay spectrum) in dB which is the same as that in the above plot.
# utils.CorrMatrix_2700ns(uvd, HHfiles, difffiles, flagfile, JD, N_threads=14)
This plot shows the ratio of delay spectrum to noise floor (averaged over 1000-4000ns). Near 1 indicates the delay spectrum reaches to the noise floor, which may mean good.
utils.plot_antFeatureMap_noise(uvd_diff, d_even, d_odd, JD, pol='nn')
--------------------------------------------------------------------------- OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 63 try: # This tries thrice with 5sec sleeps in between ---> 64 iengine = inspect(engine) 65 except OperationalError: # pragma: no cover ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8) During handling of the above exception, another exception occurred: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 69 try: ---> 70 iengine = inspect(engine) 71 except OperationalError: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8) During handling of the above exception, another exception occurred: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) /tmp/ipykernel_18964/1131690460.py in <module> ----> 1 utils.plot_antFeatureMap_noise(uvd_diff, d_even, d_odd, JD, pol='nn') ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_notebook_templates/utils.py in plot_antFeatureMap_noise(uvd, d_even, d_odd, JD, pol) 2359 2360 fig = plt.figure(figsize=(14,10)) -> 2361 nodes, antDict, inclNodes = generate_nodeDict(uvd) 2362 antnums = uvd.get_ants() 2363 cmap = plt.get_cmap('inferno') ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_notebook_templates/utils.py in generate_nodeDict(uv) 1731 1732 antnums = uv.get_ants() -> 1733 h = cm_hookup.Hookup() 1734 x = h.get_hookup('HH') 1735 nodes = {} ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/cm_hookup.py in __init__(self, session) 34 def __init__(self, session=None): 35 if session is None: # pragma: no cover ---> 36 db = mc.connect_to_mc_db(None) 37 self.session = db.sessionmaker() 38 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/mc.py in connect_to_mc_db(args, forced_db_name, check_connect) 236 db = DeclarativeDB(db_url) 237 elif db_mode == "production": --> 238 db = AutomappedDB(db_url) 239 else: 240 raise RuntimeError( ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/mc.py in __init__(self, db_url) 89 90 with self.sessionmaker() as session: ---> 91 if not is_valid_database(MCDeclarativeBase, session): 92 raise RuntimeError( 93 "database {0} does not match expected schema".format(db_url) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 71 except OperationalError: 72 time.sleep(5) ---> 73 iengine = inspect(engine) 74 75 errors = False ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 62 if reg is True: 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: 66 break ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 180 @inspection._inspects(Engine) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 184 @inspection._inspects(Connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 115 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self 119 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 126 def _init_engine(self, engine): 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True 130 self.dialect = self.engine.dialect ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3195 """ 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 3199 @util.deprecated( ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 94 connection 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) 98 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3274 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 3278 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3245 if connection is None: 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) 3249 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2099 elif should_wrap: 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) 2103 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3241 dialect = self.dialect 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: 3245 if connection is None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 308 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 312 def _return_conn(self, record): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 866 def _checkout(cls, pool, threadconns=None, fairy=None): 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 870 fairy._pool = pool ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 474 @classmethod 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: 478 dbapi_connection = rec.get_connection() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 144 except: 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: 148 return self._do_get() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 70 compat.raise_( 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) 74 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 141 if self._inc_overflow(): 142 try: --> 143 return self._create_connection() 144 except: 145 with util.safe_reraise(): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 254 """Called by subclasses to create a new ConnectionRecord.""" 255 --> 256 return _ConnectionRecord(self) 257 258 def _invalidate(self, connection, exception=None, _checkin=True): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 369 self.__pool = pool 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() 373 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 664 except Exception as e: 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: 668 # in SQLAlchemy 1.4 the first_connect event is not used by ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 70 compat.raise_( 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) 74 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 659 try: 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) 663 self.fresh = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 588 if connection is not None: 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 592 creator = pop_kwarg("creator", connect) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 582 def connect(self, *cargs, **cparams): 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 586 def create_connect_args(self, url): ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 125 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: 129 conn.cursor_factory = cursor_factory OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8)
<Figure size 1008x720 with 0 Axes>
utils.plot_antFeatureMap_noise(uvd_diff, d_even, d_odd, JD, pol='ee')
--------------------------------------------------------------------------- OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 63 try: # This tries thrice with 5sec sleeps in between ---> 64 iengine = inspect(engine) 65 except OperationalError: # pragma: no cover ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8) During handling of the above exception, another exception occurred: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 69 try: ---> 70 iengine = inspect(engine) 71 except OperationalError: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8) During handling of the above exception, another exception occurred: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) /tmp/ipykernel_18964/4223077259.py in <module> ----> 1 utils.plot_antFeatureMap_noise(uvd_diff, d_even, d_odd, JD, pol='ee') ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_notebook_templates/utils.py in plot_antFeatureMap_noise(uvd, d_even, d_odd, JD, pol) 2359 2360 fig = plt.figure(figsize=(14,10)) -> 2361 nodes, antDict, inclNodes = generate_nodeDict(uvd) 2362 antnums = uvd.get_ants() 2363 cmap = plt.get_cmap('inferno') ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_notebook_templates/utils.py in generate_nodeDict(uv) 1731 1732 antnums = uv.get_ants() -> 1733 h = cm_hookup.Hookup() 1734 x = h.get_hookup('HH') 1735 nodes = {} ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/cm_hookup.py in __init__(self, session) 34 def __init__(self, session=None): 35 if session is None: # pragma: no cover ---> 36 db = mc.connect_to_mc_db(None) 37 self.session = db.sessionmaker() 38 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/mc.py in connect_to_mc_db(args, forced_db_name, check_connect) 236 db = DeclarativeDB(db_url) 237 elif db_mode == "production": --> 238 db = AutomappedDB(db_url) 239 else: 240 raise RuntimeError( ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/mc.py in __init__(self, db_url) 89 90 with self.sessionmaker() as session: ---> 91 if not is_valid_database(MCDeclarativeBase, session): 92 raise RuntimeError( 93 "database {0} does not match expected schema".format(db_url) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 71 except OperationalError: 72 time.sleep(5) ---> 73 iengine = inspect(engine) 74 75 errors = False ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 62 if reg is True: 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: 66 break ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 180 @inspection._inspects(Engine) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 184 @inspection._inspects(Connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 115 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self 119 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 126 def _init_engine(self, engine): 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True 130 self.dialect = self.engine.dialect ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3195 """ 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 3199 @util.deprecated( ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 94 connection 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) 98 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3274 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 3278 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3245 if connection is None: 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) 3249 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2099 elif should_wrap: 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) 2103 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3241 dialect = self.dialect 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: 3245 if connection is None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 308 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 312 def _return_conn(self, record): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 866 def _checkout(cls, pool, threadconns=None, fairy=None): 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 870 fairy._pool = pool ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 474 @classmethod 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: 478 dbapi_connection = rec.get_connection() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 144 except: 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: 148 return self._do_get() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 70 compat.raise_( 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) 74 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 141 if self._inc_overflow(): 142 try: --> 143 return self._create_connection() 144 except: 145 with util.safe_reraise(): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 254 """Called by subclasses to create a new ConnectionRecord.""" 255 --> 256 return _ConnectionRecord(self) 257 258 def _invalidate(self, connection, exception=None, _checkin=True): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 369 self.__pool = pool 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() 373 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 664 except Exception as e: 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: 668 # in SQLAlchemy 1.4 the first_connect event is not used by ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 70 compat.raise_( 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) 74 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 659 try: 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) 663 self.fresh = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 588 if connection is not None: 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 592 creator = pop_kwarg("creator", connect) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 582 def connect(self, *cargs, **cparams): 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 586 def create_connect_args(self, url): ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 125 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: 129 conn.cursor_factory = cursor_factory OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8)
<Figure size 1008x720 with 0 Axes>
# get the ratio of delay spectum to noise for different freqeuncy bands and pols
ds_noise_ratio = utils.get_ds_noise_ratio(uvd, uvd_diff, bls)
nodes, antDict, inclNodes = utils.generate_nodeDict(uvd)
ants = uvd.get_ants()
# build dataframe
to_show = {'Ant': ants, 'Node': [int(antDict[ant]['node']) for ant in ants], 'Snap': [int(antDict[ant]['snapLocs'][0]) for ant in ants]}
df = pd.DataFrame(to_show)
cols_ratio = []
for key in ds_noise_ratio.keys():
if(key[0] == 40):
col = r'Full '
else:
col = r'{}-{} MHz '.format(key[0], key[1])
col += key[2]
df[col] = ds_noise_ratio[key]
cols_ratio.append(col)
# sort by node number and then by antenna number within nodes
df.sort_values(['Node', 'Ant'], ascending=True)
ratio_cut = 3
# style dataframe
table = df.style.hide_index() \
.applymap(lambda val: 'color: red' if val > ratio_cut else '', subset=cols_ratio) \
.set_table_styles([dict(selector="th",props=[('max-width', f'70pt')])])
--------------------------------------------------------------------------- OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 63 try: # This tries thrice with 5sec sleeps in between ---> 64 iengine = inspect(engine) 65 except OperationalError: # pragma: no cover ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8) During handling of the above exception, another exception occurred: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 69 try: ---> 70 iengine = inspect(engine) 71 except OperationalError: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8) During handling of the above exception, another exception occurred: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) /tmp/ipykernel_18964/2075279450.py in <module> 2 ds_noise_ratio = utils.get_ds_noise_ratio(uvd, uvd_diff, bls) 3 ----> 4 nodes, antDict, inclNodes = utils.generate_nodeDict(uvd) 5 ants = uvd.get_ants() 6 # build dataframe ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_notebook_templates/utils.py in generate_nodeDict(uv) 1731 1732 antnums = uv.get_ants() -> 1733 h = cm_hookup.Hookup() 1734 x = h.get_hookup('HH') 1735 nodes = {} ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/cm_hookup.py in __init__(self, session) 34 def __init__(self, session=None): 35 if session is None: # pragma: no cover ---> 36 db = mc.connect_to_mc_db(None) 37 self.session = db.sessionmaker() 38 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/mc.py in connect_to_mc_db(args, forced_db_name, check_connect) 236 db = DeclarativeDB(db_url) 237 elif db_mode == "production": --> 238 db = AutomappedDB(db_url) 239 else: 240 raise RuntimeError( ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/mc.py in __init__(self, db_url) 89 90 with self.sessionmaker() as session: ---> 91 if not is_valid_database(MCDeclarativeBase, session): 92 raise RuntimeError( 93 "database {0} does not match expected schema".format(db_url) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 71 except OperationalError: 72 time.sleep(5) ---> 73 iengine = inspect(engine) 74 75 errors = False ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 62 if reg is True: 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: 66 break ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 180 @inspection._inspects(Engine) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 184 @inspection._inspects(Connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 115 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self 119 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 126 def _init_engine(self, engine): 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True 130 self.dialect = self.engine.dialect ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3195 """ 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 3199 @util.deprecated( ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 94 connection 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) 98 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3274 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 3278 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3245 if connection is None: 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) 3249 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2099 elif should_wrap: 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) 2103 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3241 dialect = self.dialect 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: 3245 if connection is None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 308 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 312 def _return_conn(self, record): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 866 def _checkout(cls, pool, threadconns=None, fairy=None): 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 870 fairy._pool = pool ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 474 @classmethod 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: 478 dbapi_connection = rec.get_connection() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 144 except: 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: 148 return self._do_get() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 70 compat.raise_( 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) 74 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 141 if self._inc_overflow(): 142 try: --> 143 return self._create_connection() 144 except: 145 with util.safe_reraise(): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 254 """Called by subclasses to create a new ConnectionRecord.""" 255 --> 256 return _ConnectionRecord(self) 257 258 def _invalidate(self, connection, exception=None, _checkin=True): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 369 self.__pool = pool 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() 373 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 664 except Exception as e: 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: 668 # in SQLAlchemy 1.4 the first_connect event is not used by ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 70 compat.raise_( 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) 74 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 659 try: 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) 663 self.fresh = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 588 if connection is not None: 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 592 creator = pop_kwarg("creator", connect) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 582 def connect(self, *cargs, **cparams): 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 586 def create_connect_args(self, url): ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 125 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: 129 conn.cursor_factory = cursor_factory OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8)
This table shows the ratio of the delay spectrum to the noise level from diff files for different frequency bands and pols. The ratio > 3 is colored in red
HTML(table.render())
--------------------------------------------------------------------------- NameError Traceback (most recent call last) /tmp/ipykernel_18964/830379045.py in <module> ----> 1 HTML(table.render()) NameError: name 'table' is not defined
csv_file = os.path.join(nb_outdir, 'ds_noise_ratio_{}.csv'.format(JD))
df.to_csv(csv_file, index=False)
--------------------------------------------------------------------------- NameError Traceback (most recent call last) /tmp/ipykernel_18964/4247774082.py in <module> 1 csv_file = os.path.join(nb_outdir, 'ds_noise_ratio_{}.csv'.format(JD)) ----> 2 df.to_csv(csv_file, index=False) NameError: name 'df' is not defined
Left panel: time averaged delay spectum of autocorrelation in dB with 10*log10($|\tilde{V}|$) (blue) and noise from diff file representing the expected variance of the delay spectrum (red). The time-averaging is performed by 1. binning three time integrations of each even and odd visibility, 2. Fouier transform the binned even and odd visibilities, and 3. multiply the even and odd delay spectra at alternating time bin and average the squared delay spectrum along the time axis. This helps to reduce the noise bias. Both autocorrelation delay spectrum and diff delay spectrum are averaged in the same way
Right panel: time averaged autocorrelations w/o (orange) and w/ xRFI flags (blue). Flagged one is shifted from the unflagged one for clarity
utils.interactive_plots_dspec(bls, uvd, uvd_diff, JD)
--------------------------------------------------------------------------- OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 63 try: # This tries thrice with 5sec sleeps in between ---> 64 iengine = inspect(engine) 65 except OperationalError: # pragma: no cover ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8) During handling of the above exception, another exception occurred: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 69 try: ---> 70 iengine = inspect(engine) 71 except OperationalError: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8) During handling of the above exception, another exception occurred: OperationalError Traceback (most recent call last) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 142 try: --> 143 return self._create_connection() 144 except: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 255 --> 256 return _ConnectionRecord(self) 257 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 206 try: --> 207 raise exception 208 finally: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: OperationalError: FATAL: remaining connection slots are reserved for non-replication superuser connections The above exception was the direct cause of the following exception: OperationalError Traceback (most recent call last) /tmp/ipykernel_18964/789190876.py in <module> ----> 1 utils.interactive_plots_dspec(bls, uvd, uvd_diff, JD) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_notebook_templates/utils.py in interactive_plots_dspec(bls, uvd, uvd_diff, JD) 2488 d_odd_dict[(freq1, freq2)] = d_odd 2489 -> 2490 nodes, antDict, inclNodes = generate_nodeDict(uvd) 2491 2492 data_full = [] ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_notebook_templates/utils.py in generate_nodeDict(uv) 1731 1732 antnums = uv.get_ants() -> 1733 h = cm_hookup.Hookup() 1734 x = h.get_hookup('HH') 1735 nodes = {} ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/cm_hookup.py in __init__(self, session) 34 def __init__(self, session=None): 35 if session is None: # pragma: no cover ---> 36 db = mc.connect_to_mc_db(None) 37 self.session = db.sessionmaker() 38 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/mc.py in connect_to_mc_db(args, forced_db_name, check_connect) 236 db = DeclarativeDB(db_url) 237 elif db_mode == "production": --> 238 db = AutomappedDB(db_url) 239 else: 240 raise RuntimeError( ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/mc.py in __init__(self, db_url) 89 90 with self.sessionmaker() as session: ---> 91 if not is_valid_database(MCDeclarativeBase, session): 92 raise RuntimeError( 93 "database {0} does not match expected schema".format(db_url) ~/anaconda/envs/RTP/lib/python3.7/site-packages/hera_mc/db_check.py in is_valid_database(base, session) 71 except OperationalError: 72 time.sleep(5) ---> 73 iengine = inspect(engine) 74 75 errors = False ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/inspection.py in inspect(subject, raiseerr) 62 if reg is True: 63 return subject ---> 64 ret = reg(subject) 65 if ret is not None: 66 break ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _engine_insp(bind) 180 @inspection._inspects(Engine) 181 def _engine_insp(bind): --> 182 return Inspector._construct(Inspector._init_engine, bind) 183 184 @inspection._inspects(Connection) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _construct(cls, init, bind) 115 116 self = cls.__new__(cls) --> 117 init(self, bind) 118 return self 119 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/reflection.py in _init_engine(self, engine) 126 def _init_engine(self, engine): 127 self.bind = self.engine = engine --> 128 engine.connect().close() 129 self._op_context_requires_connect = True 130 self.dialect = self.engine.dialect ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in connect(self, close_with_result) 3195 """ 3196 -> 3197 return self._connection_cls(self, close_with_result=close_with_result) 3198 3199 @util.deprecated( ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in __init__(self, engine, connection, close_with_result, _branch_from, _execution_options, _dispatch, _has_events, _allow_revalidate) 94 connection 95 if connection is not None ---> 96 else engine.raw_connection() 97 ) 98 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in raw_connection(self, _connection) 3274 3275 """ -> 3276 return self._wrap_pool_connect(self.pool.connect, _connection) 3277 3278 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3245 if connection is None: 3246 Connection._handle_dbapi_exception_noconnection( -> 3247 e, dialect, self 3248 ) 3249 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _handle_dbapi_exception_noconnection(cls, e, dialect, engine) 2099 elif should_wrap: 2100 util.raise_( -> 2101 sqlalchemy_exception, with_traceback=exc_info[2], from_=e 2102 ) 2103 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/base.py in _wrap_pool_connect(self, fn, connection) 3241 dialect = self.dialect 3242 try: -> 3243 return fn() 3244 except dialect.dbapi.Error as e: 3245 if connection is None: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in connect(self) 308 309 """ --> 310 return _ConnectionFairy._checkout(self) 311 312 def _return_conn(self, record): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _checkout(cls, pool, threadconns, fairy) 866 def _checkout(cls, pool, threadconns=None, fairy=None): 867 if not fairy: --> 868 fairy = _ConnectionRecord.checkout(pool) 869 870 fairy._pool = pool ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in checkout(cls, pool) 474 @classmethod 475 def checkout(cls, pool): --> 476 rec = pool._do_get() 477 try: 478 dbapi_connection = rec.get_connection() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 144 except: 145 with util.safe_reraise(): --> 146 self._dec_overflow() 147 else: 148 return self._do_get() ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 70 compat.raise_( 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) 74 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/impl.py in _do_get(self) 141 if self._inc_overflow(): 142 try: --> 143 return self._create_connection() 144 except: 145 with util.safe_reraise(): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in _create_connection(self) 254 """Called by subclasses to create a new ConnectionRecord.""" 255 --> 256 return _ConnectionRecord(self) 257 258 def _invalidate(self, connection, exception=None, _checkin=True): ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __init__(self, pool, connect) 369 self.__pool = pool 370 if connect: --> 371 self.__connect() 372 self.finalize_callback = deque() 373 ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 664 except Exception as e: 665 with util.safe_reraise(): --> 666 pool.logger.debug("Error on connect(): %s", e) 667 else: 668 # in SQLAlchemy 1.4 the first_connect event is not used by ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/langhelpers.py in __exit__(self, type_, value, traceback) 70 compat.raise_( 71 exc_value, ---> 72 with_traceback=exc_tb, 73 ) 74 else: ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/util/compat.py in raise_(***failed resolving arguments***) 205 206 try: --> 207 raise exception 208 finally: 209 # credit to ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/pool/base.py in __connect(self) 659 try: 660 self.starttime = time.time() --> 661 self.dbapi_connection = connection = pool._invoke_creator(self) 662 pool.logger.debug("Created new connection %r", connection) 663 self.fresh = True ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/create.py in connect(connection_record) 588 if connection is not None: 589 return connection --> 590 return dialect.connect(*cargs, **cparams) 591 592 creator = pop_kwarg("creator", connect) ~/anaconda/envs/RTP/lib/python3.7/site-packages/sqlalchemy/engine/default.py in connect(self, *cargs, **cparams) 582 def connect(self, *cargs, **cparams): 583 # inherits the docstring from interfaces.Dialect.connect --> 584 return self.dbapi.connect(*cargs, **cparams) 585 586 def create_connect_args(self, url): ~/anaconda/envs/RTP/lib/python3.7/site-packages/psycopg2/__init__.py in connect(dsn, connection_factory, cursor_factory, **kwargs) 125 126 dsn = _ext.make_dsn(dsn, **kwargs) --> 127 conn = _connect(dsn, connection_factory=connection_factory, **kwasync) 128 if cursor_factory is not None: 129 conn.cursor_factory = cursor_factory OperationalError: (psycopg2.OperationalError) FATAL: remaining connection slots are reserved for non-replication superuser connections (Background on this error at: https://sqlalche.me/e/14/e3q8)